package com.lzq.mq.client.producer;

import com.lzq.mq.common.dto.MessageDTO;

/**
 * 生产者接口
 */
public interface Producer {

    /**
     * 同步发送
     *
     * @param messageDTO
     * @return
     */
    SendResult send(MessageDTO messageDTO);

    /**
     * 异步发送
     *
     * @param messageDTO
     * @return
     */
    void sendAsync(MessageDTO messageDTO);
}
